package com.ylr.rocket;


import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface Sink {//消费者
    String ERBADAGANG_INPUT = "order_in";

    @Input(ERBADAGANG_INPUT)
    SubscribableChannel messageChannel();

//
//    @Input("order_in")
//    public MessageChannel messageChannel() ;


}
